//package com.jsg.sl651.handler.mqtt;
//
//import com.compass.springboot3.common.StringUtils;
//import com.compass.springboot3.response.ResponseResult;
//import com.compass.springboot3.response.ResponseUtil;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Controller;
//import org.springframework.web.bind.annotation.*;
//@Controller
//@RequestMapping("/mqtt")
//public class MqttTestController {
//
//    @Autowired
//    private MQTTConnect mqttConnect;
//
//    @ResponseBody
//    @PostMapping("/mqttTest01")
//    public ResponseResult<Object> test(@RequestParam("msg") String msg,
//                                       @RequestParam("topic") String topic, @RequestParam("qos") int qos) throws Exception {
//        if (StringUtils.isBlank(topic)){
//            topic =MQTTConnect.TOPIC;
//        }
//        mqttConnect.pub(topic, msg,qos);
//        return ResponseUtil.success("ok");
//    }
//}
